package com.pactera.asmp.server.common.threadpool;

/**
 * <p>Class: com.lzq.plugin.threadpool.Test</p>
 * <p>Description: </p>
 * <pre>
 *
 * </pre>
 *
 * @author lv zhiqiang
 * @date 2019/7/17/14:58
 */

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;

/**
 * DelayedQueue是一个用来延时处理的队列，
 * 所谓延时处理就是说可以为队列中元素设定一个过期时间，
 * 相关的操作受到这个设定时间的控制。
 首先，这种队列中只能存放实现Delayed接口的对象，
 而此接口有两个需要实现的方法。最重要的就是getDelay，
 这个方法需要返回对象过期前的countdown时间。
 简单说，队列在某些方法处理前，会调用此方法来判断对象有没有超时。
 DelayedQueue本身有些类似的存取方法，按doc描述区别如下：

 ​存入队列：add offer put无太大区别

 从队列中获取：peek poll take​有较大不同使用场景

 peek：获取队列的head对象，但不是从队列中移除。如果队列空，就返回空

 poll ：​获取并移出队列head对象。如果head没有超时，返回空

 poll w/ timeout参数 ： ​获取并移出队列head对象。如果没有超时head对象，会wait当前线程知道有超时对象，或者按照超时参数设定，返回空

 take ： ​获取并移出队列head对象。如果没有超时head对象，会wait当前线程知道有对象满足超时条件

 ​DelayedQueue实现保证了最快过期的对象排在head位置，也就是说它会在每次peek时候返回最快超时的对象。
 * @author lulei
 *
 */
public class DelayedElement implements Delayed {
    private final long delay;

    private final long expire;

    public DelayedElement(long delay) {

        this.delay = delay;

        expire = Calendar.getInstance().getTimeInMillis() + delay;

    }

    @Override

    public long getDelay(TimeUnit unit) {

        return expire - Calendar.getInstance().getTimeInMillis();

    }

    @Override

    public int compareTo(Delayed o) {

        return (int) (this.delay - o.getDelay(TimeUnit.MILLISECONDS));

    }

    @Override

    public String toString() {
        SimpleDateFormat sf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        return "DelayedElement is " + delay + "\n" +
                sf.format(Calendar.getInstance().getTime()) + "\n 过期时间是"
                + getDelay(TimeUnit.DAYS);

    }

}